package org.hong.monkey.network.server;

import io.netty.channel.Channel;
import org.hong.monkey.network.buffer.ManagedBuffer;
import org.hong.monkey.network.client.TransportClient;

public abstract class StreamManager {
    public abstract ManagedBuffer getChunk(long streamId, int chunkIndex);

    public ManagedBuffer openStream(String streamId) {
        throw new UnsupportedOperationException();
    }

    public void registerChannel(Channel channel, long streamId) { }

    public void connectionTerminated(Channel channel) { }

    public void checkAuthorization(TransportClient client, long streamId) { }
}
